package event

import "context"

// Event 事件接口
type Event interface {
	Topic() string
}

// Producer 消息发送者
type Producer interface {
	Send(ctx context.Context, event Event) error
	TxSend(ctx context.Context, event Event) error
}
